package org.example
import org.apache.spark.sql.SparkSession
object class0327 {
  def main(args: Array[String]): Unit = {
    val spark = SparkSesion.builder().master("local[*]").appName("spark").getOrCreate()
    val sc = spark.sparkContext
    val rdd1 = sc.makeRDD(List(1, 5, 3, 7, 6), 1)
    val rdd2 = sc.parallelize(List(('a', 90), ('b', 78), ('c', 66), ('b', 78)))
    val rdd3 = sc.makeRDD(List(1,2,3,4,5),1)
    rdd1.intersection(rdd3).foreach(println)
    rdd1.union(rdd3).foreach(println)
    rdd1.subtract(rdd3).foreach(println)
    rdd1.zip(rdd3).foreach(println)
    rdd1.cartesian(rdd3).foreach(println)
    rdd2.filter(_._2 >= 90).doreach(println)

    rdd1.foreach(println)
    rdd2.collect().foreach(println)
    sc.stop()
  }

}
